package com.ziroom.crm.mq.core.processor;

import com.ziroom.crm.mq.core.context.InvokeContext;

/**
 * <p></p>
 * <p>
 * <PRE>
 * <BR>    修改记录
 * <BR>-----------------------------------------------
 * <BR>    修改日期         修改人          修改内容
 * </PRE>
 *
 * @author WeiShaoying
 * @version 1.0
 * @date Created in 2020年09月04日 09:58
 * @since 1.0
 */
public interface ConsumeProcessor {

    /**
     * 消费前置处理
     *
     * @param invokeContext
     * @param queueWrapper
     */
    default void preConsume(InvokeContext invokeContext, QueueWrapper queueWrapper) {
    }

    /**
     * 消费后置处理
     *
     * @param invokeContext
     * @param queueWrapper
     */
    default void postConsume(InvokeContext invokeContext, QueueWrapper queueWrapper) {
    }
}
